package com.cmb.lk50.sink.kafka;

import com.cmb.lk50.pojo.AbstractLog;

/**
 * 从log中提取出kafka的key
 *
 * Author       : 蒋俊钊 80256973
 * Date         : 2020/8/19
 * Copyright    (C) ChinaMerchantsBank
 */
public interface KafkaKeyGenerator<T extends AbstractLog> {

    String getRecordKey(T log);
}
